package PhaseThirdModuleOne;

//  MapReduce 程序读取这三个文件，对三个文件中的数字进行
//  整体升序排序，并输出到一个结果文件中，结果文件中的每
//  一行有两个数字（两个数字之间使⽤用制表符分隔)，第一
//  个数字代表排名，第二个数字代表原始数据

import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.mapreduce.Mapper;

import java.io.IOException;

public class Task01Mapper extends Mapper<LongWritable, Text, LongWritable, LongWritable> {

    @Override
    protected void map(LongWritable key, Text value, Context context) throws IOException, InterruptedException {
        //读取一行(一个)数字转换为String类型
        String s = value.toString();
        //将读取到的数字从String转换为LongWritable类型
        LongWritable num = new LongWritable(Long.parseLong(s));
        //将k(数字num)v对输出
        context.write(num, new LongWritable(1));
    }
}
